const cloud = require('wx-server-sdk')
const env = 'bbq-6gz7knah1c296b0f'
cloud.init(env)

const db = cloud.database({ env })

// 云函数入口函数
exports.main = async (event, context) => {
  if(event.code == 0){  //获取某一对话数据，如果没有，则创建
    //判断是否已有对话
    var res = await db.collection('talks').where({
      talkers:event.talkers
    }).get()

    if(!res.data.length){
      return await db.collection('talks').add({
        data:{
          talkers:event.talkers
        }
      })
    }
    return res


  }else if(event.code == 1){  //获取所有对话数据
    return await db.collection('talks').get()
  }else if(event.code == 2){ //发送消息
   await db.collection('talks').doc(event.talkId)
    .update({
      data:{
        messages:db.command.push(event.messages)
      }
    })

    return await db.collection('talks').doc(event.talkId).get()
  }

}